package so.sao.code.service.infrastructure.stream;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import so.sao.code.service.infrastructure.stream.channel.ThirdPartyTagInChannel;
import so.sao.top.core.util.mapper.JsonMapper;

/**
 * Created by Administrator on 2017/12/8.
 */
@EnableBinding(value = ThirdPartyTagInChannel.class)
public class ConsumeManager {
	
    @Autowired
    JsonMapper jsonMapper;
    
    @StreamListener(ThirdPartyTagInChannel.THIRD_PARTY_TAG_IN)
    public void input(Object payload) {
        System.out.println("供应链发送数据："+payload);
    }
}
